package com.ddpt.platform.common.async.service;

/**
 * 各自服务需要自行实现该service
 */
public interface AsyncProcessService {

    /**
     * 处理消息
     * @param route 路由
     * @param value 消息内容
     * @param timeStamp 任务投递的时间
     * @param serialNumber  本条消息的流水号(各业务用于处理去重和幂等)
     */
    void process(String route,String value,Long timeStamp,String serialNumber);
}
